package Dedup;

import java.io.IOException;
import org.apache.hadoop.io.*;
import org.apache.hadoop.mapreduce.Reducer;

public class DedupReducer extends Reducer<Text,Text,Text,Text>{
    //实现reduce函数
    public void reduce(Text key,Iterable<Text> values,Context context)
            throws IOException,InterruptedException{
        context.write(key, new Text(""));
    }
}
